package com.xbstar.datafusion;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.EnableKafka;

/**
 * Created by jiwenfei on 2018/1/30 14:49 .
 */
@SpringBootApplication
@EnableKafka
public class Application {
    public static void main( String[] args ) {
        SpringApplication.run(Application.class,args);
    }
}
/***
 * 1. 如果影子或者，则认为可以接收数据。如果此时系统死掉，比如500，则调用此系统的front，发送新的消息到平台中，
 * 发送信息者根据收到的消息状态进行处理
 * 2. 如果双方系统都同时死掉，则进行消息杀死机制
 * 3. 消息发送时，如果影子死掉，则进入重复队列，等到影子存活时，再进行发送，并给消息发送者发送成功但未保存字段
 */